package com.allen.flink.dbus.sink;

import lombok.Data;
import lombok.ToString;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;

/**
 * 功能:  HBase操作对象类
 *
 * @date: 2020-03-26 17:16
 * @author: Allen
 * @version: 0.0.4-snapshot
 * @Email: allenZyhang@163.com
 * @since: JDK 1.8
 **/
@ToString
@Data
public class HRow implements Serializable {
    private byte[] rowKey;
    private List<HCell> cells = new ArrayList<>();
    
    public void addCell(String family, String qualifier, byte[] value) {
        HCell hCell = new HCell(family, qualifier, value);
        cells.add(hCell);
    }
}
